package cc.autoapi.pucong.auto.flow.core.flow.execNode.streamBus;

public interface IStreamPublisher {


    /**
     * 触发消息
     */
    void send(String msg);

    /**
     * 完成
     */
    void complete();
}
